#include "mysql_aliyun.h"

IPAddress server_addr(47,92,173,239);    // 安装Mysql的电脑的IP地址
char user[]="lin";                     // Mysql的用户名
char password[] = "lin456";                  // 登陆Mysql的密码
WiFiClient client;                        // 声明一个Mysql客户端，在连接Mysql中使用
MySQL_Connection conn(&client);
MySQL_Cursor* cursor;

//cursor = new MySQL_Cursor(&conn);

bool Mysql_judge_connect() {        //此函数判断是否连接到数据库

    bool return_info;
    Serial.println("Connecting to MYSQL...  ");
    if (conn.connect(server_addr, 3306, user, password)) {        // 连接数据库
        return_info=1;
//    Serial.println("成功连接数据库---OK.");
//    Serial.println();
    } else {
        return_info=0;
//    Serial.println("连接数据库失败---FAILED.");
    }
    return return_info;
}
void Send_info(char tem[5],char hum[4],char light[4]) {     //传入三个参数，再插入到SQL语句中
    char buff[128];// 定义存储传感器数据的数组
    char INSERT_SQL[] = "INSERT INTO  template.gjx(temprature,humidity,light) VALUES ('%s','%s','%s')";

    sprintf(buff,INSERT_SQL,tem,hum,light); // 将tem和hem中数据放入SQL中sprintf()函数详情https://blog.csdn.net/oyhb_1992/article/details/75095472
    
    Mysql_insert(buff);
}

void Mysql_insert(char buff[128]) {                  //此函数把前面处理好的SQL语句传传入MYSQL
    MySQL_Cursor *cur_mem = new MySQL_Cursor(&conn); // 创建一个Mysql实例
    cur_mem->execute(buff);         // 将采集到的温湿度值插入数据库中
    Serial.println("读取传感器数据，并写入数据库");
    delete cur_mem;        // 删除mysql实例为下次采集作准备
}
